// 版权所有2011 Go作者。版权所有。
// 此源代码的使用受BSD样式
// 许可证的约束，该许可证可以在许可证文件中找到。

package http

import (
	"fmt"
	"io"
)

// fileTransport为“file”协议实现往返程序。
type fileTransport struct {
	fh fileHandler
}

// NewFileTransport返回一个新的往返程序，为提供的
// 文件系统提供服务。返回的RoundTripper忽略其
// 传入请求中的URL主机，以及
// 请求的大多数其他属性。
// 
// NewFileTransport的典型使用案例是使用传输注册“文件”
// 协议，如：
// 
// t:=&http.Transport{}
// t.RegisterProtocol（“文件”，http.NewFileTransport（http.Dir（“/”）
// res，err:=c.Get（'file:
// /…
func NewFileTransport(fs FileSystem) RoundTripper {
	return fileTransport{fileHandler{fs}}
}

func (t fileTransport) RoundTrip(req *Request) (resp *Response, err error) {
	// 我们在一个goroutine中启动ServeHTTP，如果文件很大，这可能需要很长的
	// 时间。新的populateResponseWriter 
	// 调用返回一个ServeHTTP或finish（）的通道
	// 在*响应本身被填充后发送我们的*响应
	// 即使主体本身仍然被
	// 写入到res.主体，一个管道）
	rw, resc := newPopulateResponseWriter()
	go func() {
		t.fh.ServeHTTP(rw, req)
		rw.finish()
	}()
	return <-resc, nil
}

func newPopulateResponseWriter() (*populateResponse, <-chan *Response) {
	pr, pw := io.Pipe()
	rw := &populateResponse{
		ch: make(chan *Response),
		pw: pw,
		res: &Response{
			Proto:      "HTTP/1.0",
			ProtoMajor: 1,
			Header:     make(Header),
			Close:      true,
			Body:       pr,
		},
	}
	return rw, rw.ch
}

// populateResponse是一个ResponseWriter，它以res填充*Response 
// ，并将其主体写入连接到响应
// body的管道。一旦调用writes begin或finish（），将在ch.
// 
type populateResponse struct {
	res          *Response
	ch           chan *Response
	wroteHeader  bool
	hasContent   bool
	sentResponse bool
	pw           *io.PipeWriter
}

func (pr *populateResponse) finish() {
	if !pr.wroteHeader {
		pr.WriteHeader(500)
	}
	if !pr.sentResponse {
		pr.sendResponse()
	}
	pr.pw.Close()
}

func (pr *populateResponse) sendResponse() {
	if pr.sentResponse {
		return
	}
	pr.sentResponse = true

	if pr.hasContent {
		pr.res.ContentLength = -1
	}
	pr.ch <- pr.res
}

func (pr *populateResponse) Header() Header {
	return pr.res.Header
}

func (pr *populateResponse) WriteHeader(code int) {
	if pr.wroteHeader {
		return
	}
	pr.wroteHeader = true

	pr.res.StatusCode = code
	pr.res.Status = fmt.Sprintf("%d %s", code, StatusText(code))
}

func (pr *populateResponse) Write(p []byte) (n int, err error) {
	if !pr.wroteHeader {
		pr.WriteHeader(StatusOK)
	}
	pr.hasContent = true
	if !pr.sentResponse {
		pr.sendResponse()
	}
	return pr.pw.Write(p)
}
